//package com.tianji.promotion.controller;
//
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.PathVariable;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//import javax.annotation.Resource;
//
///**
// * @author Yandel
// * @date 2025/8/22 下午6:45
// * @description: kafka测试
// */
//@Api(tags = "Kafka测试接口")
//@RestController
//@RequestMapping("/kafka")
//public class KafkaTestController {
//
//    @Resource
//    private KafkaTemplate<String, String> kafkaTemplate;
//
//    @ApiOperation("发送消息")
//    @GetMapping("/send/msg")
//    public String sendMsg() {
//        String msg = "hello kafka";
//        kafkaTemplate.send("test-topic", msg);
//        return "消息已发送: " + msg;
//    }
//
//}
